# -*- coding: utf-8 -*-
"""
@Time : 2024/4/2 13:41
@Author : ChenXiaoliang
@Email : middlegod@sina.com
@File : get_news.py
"""

import time

import requests


def get_news():
    url = "https://api-one-wscn.awtmt.com/apiv1/content/lives?channel=a-stock-channel&client=pc&limit=10&first_page=true&accept=live%2Cvip-live"
    for _ in range(20):
        try:
            resp = requests.get(url=url).json()
            news = resp['data']['items']
            outputs = []
            for new in news:
                temp = {'title': new['title'] if new['title'] else new['content_text'].split('。', 1)[0],
                        'content_text': new['content_text'], 'important': new['score'],
                        'display_time': new['display_time']}
                outputs.append(temp)
            return outputs
            # return [{'title': '金龙：比亚迪或6月试点钠电池两轮车充换电应用',
            #          'content_text': '在日前于苏州举办的第二届钠电池产业峰会上，比亚迪弗迪电池产品线总监张剑介绍，预计比亚迪将在6月于深圳实现大圆柱钠离子电池电动两轮车充换电综合应用场景试点，实现车、柜、电智能一体化。（澎湃）',
            #          'important': 1, 'display_time': 1712229244},
            #         {'title': '收评：深交所：终止方向电子创业板IPO审核',
            #          'content_text': '据深交所披露，因深圳市方向电子股份有限公司、保荐人撤回发行上市申请，根据《深圳证券交易所股票发行上市审核规则》第六十二条，深交所决定终止其发行上市审核。',
            #          'important': 1, 'display_time': 1712229181}]

        except requests.exceptions.ConnectionError as err:
            print(time.strftime("%H:%M:%S"), err.response)
            time.sleep(20)
        except KeyError as err:
            print("发生了KeyError", err)
            time.sleep(20)


if __name__ == "__main__":
    r = get_news()
    print(r)
